package tjs.study.notes.dotest.disruptor.parallel.spring;

import com.lmax.disruptor.WorkHandler;

public class DisruptorConsumer implements WorkHandler<DisruptorNotice> {

    private String consumerId;
    
    public DisruptorConsumer(String consumerId) {
        this.consumerId = consumerId;
    }

    public void onEvent(DisruptorNotice event) throws Exception {
        System.err.println("当前消费者: " + this.consumerId + ", 消费信息ID: " + event.getNoticeJson());
    }
    

}